package com.bjpowernode.dao;

import com.bjpowernode.beans.User;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;


//JDBC操作
//查询：DQL，返回的是结果集
//1——获取java.sql.Connection对象
//2——撰写查询的SQL语句
//3——使用java.sql.Connection对象获取PreparedStatement陈述对象
//4——利用陈述对象执行查询的SQL语句
//5——返回结果集对象
//6——遍历结果集对象
//7——组装Java对象
//8——添加到Java集合对象
//9——关闭java.sql.Connection对象
public class UserDaoImp implements UserDao {
    @Override
    public ArrayList<User> getAll() throws SQLException {

        ArrayList<User> users=new ArrayList<>();
        //1——获取java.sql.Connection对象
        Connection cn = DB.getCn();
        //2——撰写查询的SQL语句
        String sql="select id,name,password from user";
        //3——使用java.sql.Connection对象获取PreparedStatement陈述对象
        PreparedStatement ps = cn.prepareStatement(sql);

        //4——利用陈述对象执行查询的SQL语句
        //5——返回结果集对象
        ResultSet rs = ps.executeQuery();
        //6——遍历结果集对象
         while (rs.next()){
             //7——组装Java对象
             User user=new User();
             user.setId(rs.getString("id"));
             user.setName(rs.getString("name"));
             user.setPassword(rs.getString("password"));
             //8——添加到Java集合对象
             users.add(user);
         }
        //9——关闭java.sql.Connection对象
        DB.closeCn();
        return users;
    }
}
